//package io.renren.socket.client.test;
//
//import java.io.IOException;
//import java.nio.ByteBuffer;
//import java.util.List;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//
//import io.renren.modules.iotp.entity.IOTPBean;
//import io.renren.modules.iotp.entity.IOTPBody;
//import io.renren.modules.iotp.utils.Code;
//import io.renren.modules.iotp.utils.IotpBodyUtils;
//
///**
// * 控制系统的 socket异步连接
// * 
// * @author lfy.xys
// * @date 2018年5月22日
// *
// */
//public class CtrlConnClientRunnable extends NioAbstractClient implements Runnable {
//
//	private static Logger logger = LoggerFactory.getLogger(CtrlConnClientRunnable.class);
//	
//	public CtrlConnClientRunnable(String ip, int port, List<byte[]> sendMsg) {
//		super(ip, port, sendMsg);
//	}
//
//	@Override
//	public void run() {
//		try {
//			logger.info(ip + ":" + port); 
//			this.connect(); 
//		} catch (Exception e) {
//			e.printStackTrace();
//		}finally{
//			if(client!=null) {
//				try {
//					rBuffer.clear();
//					client.close();
//					logger.info("关闭 {}:{} 的连接", ip, port);
//				} catch (IOException e) {
//					e.printStackTrace();
//				}
//			}
//		}
//	} 
//	
//	@Override
//	public void sendMsg() {
//		for (byte[] bs : sendMsg) {
//			try {
//				client.write(ByteBuffer.wrap(bs));
//			} catch (IOException e) {
//				e.printStackTrace();
//			}
//		}
//		
//	}
//
//	@Override
//	public boolean receiveMsg(byte[] bytes) {
//		IotpBodyUtils ibu = new IotpBodyUtils();
//		IOTPBean iotpBean = ibu.toIotpBean(bytes);
//		
//		IOTPBody body = iotpBean.getBody();
//		if(body != null) {
//			//解析成功
//		}else {
//			// 不成功，返回true，继续接收消息
//			return true;
//		}
//		
//		logger.info("body:" + body.toString());
//		// 获得协议体
//		List<String> list = body.getBodyList();
//		String resultMsg = list.toString();
//		logger.info("接收到结果：{}", resultMsg);
//		
//		// 成功，返回false，停止接收消息，close
//		return false;
//	}
//
//}
